package org.dingfugui.triple.protocol.binary.aio;

import java.nio.ByteBuffer;

/**
 * Created by fugui.ding on 2015/4/20.
 */
public class AioReader implements Runnable {
    private ByteBuffer buffer = ByteBuffer.allocate(1024);
    private AioProducerConnection con;

    public AioReader(AioProducerConnection con) {
        this.con = con;
    }

    @Override
    public void run() {
        con.read(this);
    }

    public ByteBuffer getBuffer() {
        return buffer;
    }
}
